package com.enjoyor.soa.traffic.api.kernel.databus;
 
import java.io.InputStream;

import com.enjoyor.soa.traffic.util.pojo.ResultPojo;
public interface IDubboKernelDataBusService { 
	/**
	 * 获取可用的处理类列表
	 * @return
	 */
	public ResultPojo getProcessors();
	/**
	 * 获取可用的数据源类列表
	 * @return
	 */
	public ResultPojo getFromEndpoints ();
	/**
	 * 获取可用的转发类列表
	 * @return
	 */
	public ResultPojo getToEndpoints();
	
	/**
	 * 获取可用路由列表
	 * @return
	 */
	public ResultPojo getRoutes();
	/**
	 * 获取指定id的路由
	 * @param routeId
	 * @return
	 */
	public ResultPojo getRoute(String routeId);
	/**
	 * 添加路由
	 * @return
	 */
	public ResultPojo addRoute();
	/**
	 * 删除路由文件
	 * @param routeId
	 * @return
	 */
	public ResultPojo deleteRoute(String routeId);
	/**
	 * 开始执行路由
	 * @param routeId
	 * @return
	 */
	public ResultPojo startRoute(String routeId);
	/**
	 * 停止路由执行
	 * @param routeId
	 * @return
	 */
	public ResultPojo stopRoute(String routeId);
	/**
	 * 上传处理类
	 * @param file
	 * @param name
	 * @return
	 */
	public ResultPojo upLoadProcessor(InputStream  file,String name);
	/**
	 * 上传数据获取类
	 * @param file
	 * @param name
	 * @return
	 */
	public ResultPojo upLoadFromEndpoint(InputStream  file,String name);
	/**
	 * 上传数据转发类
	 * @param file
	 * @param name
	 * @return
	 */
	public ResultPojo upLoadToEndpoint(InputStream  file,String name);
}
